package com.yj.business

import org.apache.spark.sql.SparkSession
import org.apache.spark.{SparkConf, SparkContext}

object Test1 {

  def main(args: Array[String]): Unit = {
    val conf = new SparkConf().setMaster("local[2]").setAppName("appName")
    val sc = new SparkContext(conf)
    val spark = SparkSession.builder.config(conf).getOrCreate()
    val df = spark.read.csv("C:\\Users\\Administrator\\Desktop\\yangjian\\testDir\\test.csv")
    df.show()
  }
}
